from concurrent.futures import ProcessPoolExecutor
from jobs.ibdi_job import IbdiJob
from jobs.kvbin_job import KvbinJob

from utils.log import logger

def run(job):
    job().run(7)

def main() -> None:
    logger.info("Satrt running Process Pool")
    job_list = [IbdiJob, KvbinJob]
    max_worker = len(job_list)
    with ProcessPoolExecutor(max_workers=max_worker) as executor:
        executor.map(run, job_list)
